import threading
import time


def product(c):
    # print(threading.currentThread().name)
    c.send(None)
    for i in range(1, 4):
        print("蒸包子：{}".format(i))
        res = c.send('asd')
        print("客户反馈：{}".format(res))
        time.sleep(1)
    c.close()


def eat():
    # print(threading.currentThread().name)
    res = ''
    while True:
        bz = yield res
        if not bz:
            return
        print("吃包子：{}".format(bz))
        res = "真好吃"


cs = eat()
product(cs)
